#!/bin/bash
set -eo pipefail
cd /opt/export/

runday="{{ execution_date | cst_ds }}"

rm -rf /opt/export/T-1全国时效分析_$runday.zip

hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_北京河北天津_$runday             /opt/export/T-1全国时效分析_北京河北天津_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_粤东_$runday                 /opt/export/T-1全国时效分析_粤东_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_福建陕西东莞_$runday             /opt/export/T-1全国时效分析_福建陕西东莞_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_苏南苏北_$runday                 /opt/export/T-1全国时效分析_苏南苏北_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_安徽上海_$runday               /opt/export/T-1全国时效分析_安徽上海_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_杭州温台_$runday                 /opt/export/T-1全国时效分析_杭州温台_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_广州_$runday                 /opt/export/T-1全国时效分析_广州_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_深圳湖南_$runday                 /opt/export/T-1全国时效分析_深圳湖南_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_山东黑龙江辽宁吉林_$runday            /opt/export/T-1全国时效分析_山东黑龙江辽宁吉林_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_其他_$runday                   /opt/export/T-1全国时效分析_其他_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_金华1_$runday                  /opt/export/T-1全国时效分析_金华1_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_金华2_$runday                  /opt/export/T-1全国时效分析_金华2_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_经济圈_$runday                        /opt/export/T-1全国时效分析_经济圈_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_宁波粤西_$runday                        /opt/export/T-1全国时效分析_宁波粤西_$runday
hdfs dfs -get -f /report/T-1全国时效分析/T-1全国时效分析_广西湖北川藏_$runday                        /opt/export/T-1全国时效分析_广西湖北川藏_$runday

zip /opt/export/T-1全国时效分析_$runday.zip  /opt/export/T-1全国时效分析_北京河北天津_$runday/* /opt/export/T-1全国时效分析_粤东_$runday/* /opt/export/T-1全国时效分析_福建陕西东莞_$runday/* /opt/export/T-1全国时效分析_苏南苏北_$runday/* /opt/export/T-1全国时效分析_安徽上海_$runday/* /opt/export/T-1全国时效分析_杭州温台_$runday/* /opt/export/T-1全国时效分析_广州_$runday/* /opt/export/T-1全国时效分析_深圳湖南_$runday/* /opt/export/T-1全国时效分析_山东黑龙江辽宁吉林_$runday/* /opt/export/T-1全国时效分析_其他_$runday/* /opt/export/T-1全国时效分析_金华1_$runday/* /opt/export/T-1全国时效分析_金华2_$runday/* /opt/export/T-1全国时效分析_经济圈_$runday/* /opt/export/T-1全国时效分析_宁波粤西_$runday/* /opt/export/T-1全国时效分析_广西湖北川藏_$runday/*


/usr/local/python3/bin/python3  /usr/local/airflow/dags/utils/operators/upload_oss.py  T-1全国时效分析/T-1全国时效分析_$runday.zip  /opt/export/T-1全国时效分析_$runday.zip

data_size=$(ls -lh T-1全国时效分析_$runday.zip | awk '{print $5}')
Message="T-1全国时效分析_$runday 报表上传成功 大小: $data_size"

curl 'https://oapi.dingtalk.com/robot/send?access_token=816a8f35fd84432ffa6bff9d7714abc322628bb4a8ded86908550d2335aba613' \
   -H 'Content-Type: application/json' \
   -d "
  {\"msgtype\": \"text\",
    \"text\": {
        \"content\": \"监控内容:$Message\"
     }
  }" || true

rm -rf /opt/export/T-1全国时效分析_北京河北天津_$runday
rm -rf /opt/export/T-1全国时效分析_粤东_$runday
rm -rf /opt/export/T-1全国时效分析_福建陕西东莞_$runday
rm -rf /opt/export/T-1全国时效分析_苏南苏北_$runday
rm -rf /opt/export/T-1全国时效分析_安徽上海_$runday
rm -rf /opt/export/T-1全国时效分析_杭州温台_$runday
rm -rf /opt/export/T-1全国时效分析_广州_$runday
rm -rf /opt/export/T-1全国时效分析_深圳湖南_$runday
rm -rf /opt/export/T-1全国时效分析_山东黑龙江辽宁吉林_$runday
rm -rf /opt/export/T-1全国时效分析_其他_$runday
rm -rf /opt/export/T-1全国时效分析_金华1_$runday
rm -rf /opt/export/T-1全国时效分析_金华2_$runday
rm -rf /opt/export/T-1全国时效分析_经济圈_$runday
rm -rf /opt/export/T-1全国时效分析_宁波粤西_$runday
rm -rf /opt/export/T-1全国时效分析_广西湖北川藏_$runday